const cloud = require('wx-server-sdk');

cloud.init({
  env: cloud.DYNAMIC_CURRENT_ENV
});

const db = cloud.database();

// 创建集合云函数入口函数
exports.main = async (event, context) => {
  try {
    // 创建集合
    await db.createCollection('weather');
    // await db.collection('weather').add({
    //   // data 字段表示需新增的 JSON 数据
    //   data: {
    //     region: '华东',
    //     city: '上海',
    //     sales: 11
    //   }
    // });
    // await db.collection('sales').add({
    //   // data 字段表示需新增的 JSON 数据
    //   data: {
    //     region: '华东',
    //     city: '南京',
    //     sales: 11
    //   }
    // });
    // await db.collection('sales').add({
    //   // data 字段表示需新增的 JSON 数据
    //   data: {
    //     region: '华南',
    //     city: '广州',
    //     sales: 22
    //   }
    // });
    const { weatherList } = event;
    for (let index = 0; index < weatherList.length; index++) {
      const { fxLink, now, refer } = weatherList[index]; // 当前数据的响应式页面，便于嵌入网站或应用
      const { temp, windScale, icon, text } = now; // 温度 风力 天气状况图标代码  天气状况描述
      const { sources } = refer; // 原始数据来源
      await db.collection('weather').add({
        // data 字段表示需新增的 JSON 数据
        data: {
          temp,
          windScale,
          icon,
          text,
          fxLink,
          sources
        }
      });
      
    }
    return {
      success: true
    };
  } catch (e) {
    // 这里catch到的是该collection已经存在，从业务逻辑上来说是运行成功的，所以catch返回success给前端，避免工具在前端抛出异常
    return {
      success: true,
      data: 'create collection success'
    };
  }
};
